package com.sh.data.engine.domain.datadev.flink.model.domain;

import lombok.Data;

import java.util.List;

/**
 * @author: zigui.zdf
 * @description:
 * @date: 2021/6/4 10:34
 */
@Data
//@ApiModel
public class FlinkSourceDomain {

    /**
     * 数据源类型
     */
//    @ApiModelProperty(value = "数据源类型")
    private String dsType;

    /**
     * 数据源id
     */
//    @ApiModelProperty(value = "数据源id")
    private Long dsId;

    /**
     * 映射表
     */
//    @ApiModelProperty(value = "映射表")
    private String mappingTableName;

    /**
     * 映射字段
     */
//    @ApiModelProperty(value = "字段")
    private List<FlinkFieldDomain> fieldList;

    /**
     * 时间特征：procTime,eventTime
     */
//    @ApiModelProperty(value = "时间特征：0-procTime,1-eventTime")
    private Integer timeType;

    /**
     * 并行度
     */
//    @ApiModelProperty(value = "并行度")
    private Integer parallel;

    //    @ApiModelProperty(value = "kafka类型的源配置")
    private KafkaSourceDomain kafkaSource;
}
